package com.aos.iot.socket.common.store.pubsub;


import com.aos.iot.socket.common.message.Message;

public interface PubSubStore<M extends Message> {

    void publish(String clusterName, M msg);

    void subscribe(String clusterName, PubSubListener<M> listener, Class<M> clazz);

    void unsubscribe(String clusterName);

    void shutdown();

}
